package com.stream.stream.receiver;

import com.springcoud.domain.springcouddomain.User;
import com.stream.stream.Processor;
import com.stream.stream.Processor2;
import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.annotation.StreamListener;
import org.springframework.stereotype.Component;

@Component
@EnableBinding(value = {Processor.class, Processor2.class})
public class ReveiverController2 {

	@StreamListener(Processor.INPUT)
	public void receiverIn(User user){
		System.out.println("input接收到的消息"+user.getId()+"-------"+user.getName());
	}





/*
	@StreamListener(Processor2.OUTPUT)
	public void receiverOut(User user){
		System.out.println("outPut接收到的消息"+user.getId()+"-------"+user.getName());
	}
*/


}
